package com.duobaoyu.dby.supply.biz.service.queue.service;

import com.alibaba.fastjson.JSON;
import com.duobaoyu.dby.common.core.constant.StringPool;
import com.duobaoyu.dby.supply.biz.service.queue.core.DistributionQueueMessage;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * Created by shuming on 2023/9/28 13:42
 */
@Slf4j
@Component
public class NoOpAbstractDistributionQueueJobConsumer extends AbstractDistributionQueueJobConsumer {
	@Override
	public String topicName() {
		return StringPool.ASTERISK;
	}

	@Override
	public void consume(DistributionQueueMessage distributionQueueMessage) {
		log.info("print distributionQueueMessage = {}", JSON.toJSONString(distributionQueueMessage));
	}
}
